package com.github.yoojia.mqtt;

import com.parkingwang.lang.Filter;

/**
 * 本地消息过滤器。
 * 在处理消息时为本地处理，消息已经从服务端获取到本地服务。
 * @author Yoojia Chen (yoojiachen@gmail.com)
 * @since 1.0.0
 */
public interface LocalFilter extends Filter<Message>{

    class Any implements LocalFilter {
        @Override
        public boolean test(Message item) {
            return true;
        }

        public static Any create(){
            return new Any();
        }
    }

}
